# 启动task
# celery -A celery_tasks.main worker -l info

# 指定协程做 1000 个协程
# celery -A celery_tasks.main worker -l info -P eventlet -c 1000


from celery import Celery

# 为celery使用django配置文件进行设置
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'meiduo_01.settings.dev'

# 创建Celery实例
celery_app = Celery('meiduo_01')

# 加载配置
celery_app.config_from_object('celery_tasks.config')

# 注册任务
# celery_app.autodiscover_tasks('celery_tasks.sms')  要是列表！！！老师犯过的错哈哈哈哈
# celery_app.config_from_object(['celery_tasks.main'])  这都能写错
# celery_app.config_from_object(['celery_tasks.sms'])  。。。。这错的。。。
# celery_app.autodiscover_tasks(['celery_tasks.sms', 'send_verify_mail'])
celery_app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email'])
